package com.xhg.mqtt.listener;

import java.util.Map;

/**
  * 消息监听接口
  * @Description
  * @author E.T
  * @date 2018-07-23 11:15
  * @updateby
  * @updatedate
  * @version 1.0
  * @since 1.0
  */
public interface MessageListener {
     /**
      *监听回传信息
      */
	public void messageArrived(byte[] message);

    /**
     * 失败消息处理
     * @param failMsgMap 失败消息
     * @return 消息id
     * @throws Exception
     */
	public String failMessage(Map<String, MessageEvent> failMsgMap);

  /**
   * 连接成功回调(初始化连接的时候调用，与重连区分开来，历史遗留问题)
   */
  public void connectComplete(boolean isConnect);

  /**
   * 重连回调
   * @param isConnect 是否已重连(true 重连成功，false正在重连中)
   * @throws Exception
   */
  public void reconnect(boolean isConnect);

}
